Testing Polyglot Persistence Done Right

@Inject
PhoneService phoneService;

@Test
public void should_insert_phone() {
	phoneService.save(new Phone());
}

@Test
public void should_count_phones() {
	int numberOfPhones = phoneService.count(); (1)
	assertThat(numberOfPhones, equalTo(??));
}

import static com.lordofthejars.nosqlunit.mongodb.ManagedMongoDb.MongoServerRuleBuilder.newManagedMongoDbRule;

@ClassRule
public static ManagedMongoDb managedMongoDb = newManagedMongoDbRule().mongodPath("/opt/mongo").build(); (1)

@Rule
public MongoDbRule remoteMongoDbRule = new MongoDbRule(mongoDb().databaseName("test").host("host").build());; (1)

@Test
    @UsingDataSet(locations="initialData.json", loadStrategy=LoadStrategyEnum.CLEAN_INSERT) (2)
    @ShouldMatchDataSet(location="expectedData.json") (3)
    public void book_should_be_inserted_into_repository() {

{
    "Book":
    [
        {"title":"The Hobbit","numberOfPages":293},
        {"title":"The Lord Of The Rings","numberOfPages":1299}
    ]
}

@Stateless
public class SeriesWithPersistenceContext {

	@PersistenceContext
	private EntityManager entityManager;

	public void createSerie(Serie serie) {
		this.entityManager.persist(serie);
	}
}

@Resource
String host;

@Resource
int port;

@PostConstruct
private void initDB() {
    try {
        Mongo m = new Mongo(host, port);
        DB db = m.getDB("personDB");
        //...
    } catch (UnknownHostException ex) {
        getLogger(PersonSessionBean.class.getName()).log(Level.SEVERE, null, ex);
    }
}